package com.ruyuan.event.streaming.utils;
import org.apache.hadoop.hbase.util.Bytes;

/**
 * 常量信息
 * */
public class Constants {
    public static String CLIENT_LOG = "client_log";
    public static String HBASE_TABLE = "events_db:users";
    public static String BROKERS = "hadoop5:9092";
    public static Integer REDIS_PORT = 6379;
    public static String HOST = "hadoop5";
    public static String HOSTNAME = "hadoop5";
    public static String ZOOKEEPER_PORT = "2181";
    public static String RULE_TYPE_LOGIN="login";
    public static String RULE_TYPE_OPER="oper";
    public static String OPER_CHANGE_PHONE = "57";

    //双流拼接
    public static String KAFKA_EVENT_SERVER_LOG = "event_server_log";
    public static String KAFKA_EVENT_CLIENT_LOG = "event_client_log";
    public static String KAFKA_EVENT_JOIN_LOG = "event_join_log";
    public static String KAFKA_EVENT_JOIN_REPORT = "event_join_report";
    public static String KAFKA_EVENT_RETRY_LOG = "event_retry_log";
    public static String HBASE_EVENT_SERVER_LOG_TABLE = "events_db:server_log";
    public static final byte[] HBASE_EVENT_SERVER_COLUMN_FAMILY_BASIC = Bytes.toBytes("basic") ;
    public static final byte[] HBASE_EVENT_SERVER_COLUMN_FAMILY_USERINFO = Bytes.toBytes("userInfo") ;
    public static final byte[] HBASE_EVENT_SERVER_COLUMN_FAMILY_EVENTINFO = Bytes.toBytes("eventInfo") ;
    public static final int DEFAULT_TTL = 2 * 60 * 60;
    public static String HDFS_LOG_DIR = "/user/hive/warehouse";
}